package activemq;

import org.apache.activemq.broker.BrokerService;

/**
 * @author lishaojun
 * @create 2019-07-18-下午 5:43
 * 迷你版小型activemq中间件
 */
public class EmbedBroker {
    public static void main(String[] args) throws Exception {
        BrokerService brokerService=new BrokerService();
        brokerService.setUseJmx(true);
        brokerService.addConnector("tcp://127.0.0.1:61616");
        brokerService.start();
    }
}
